package broker

// 通过 inputch 写入logdb
var inputch_log = make(chan string, 5000)

func Input2db_log(str string) {
	inputch_log <- str
}

func Inputch_log() chan string {
	return inputch_log
}

// 通过 inputch 写入workdb
var inputch_work = make(chan string, 5000)

func Input2db_work(str string) {
	inputch_work <- str
}

func Inputch_work() chan string {
	return inputch_work
}
